<!DOCTYPE html>
<html lang="en">
  <head>
    <meta charset="UTF-8" />
    <meta http-equiv="X-UA-Compatible" content="IE=edge" />
    <meta name="viewport" content="width=device-width, initial-scale=1.0" />
    <title>Document</title>
  </head>
  <body>
    <!-- 
      并发调度器的主要思想：
        先存储好所有的promise方法，然后通过limit限制发起的请求，用count记录当前正在
        执行的请求，先发起limit个数的请求，并没发起一个请求count++，保证count<=limit
        每请求完，count--,继续向下请求，知道请求完毕
     -->
    <script>
      class Scheduler {
        constructor(limit) {
          this.queue = [];//存储promise方法
          this.limit = limit; //可以同时处理多少个请求
          this.count = 0;//正在请求的个数
        }
        // 添加promise方法
        add(time, order) {
          const promiseCreator = () => {
            return new Promise((resolve, rejected) => {
              setTimeout(() => {
                console.log(order);
                resolve();
              }, time);
            });
          };
          this.queue.push(promiseCreator);
        }
        // 一键发起前面limit个请求
        taskStart() {
          for (let i = 0; i < this.limit; i++) {
            this.request();
          }
        }
        //对处理请求进行限制，处理完了可以处理下一个
        request() {
          if (!this.queue.length || this.count > this.limit) return;
          // 只要运行了request就count+1,this.count<this.limit保证了每次处理两个请求
          this.count++;
          this.queue.shift()().then(() => {
            // 进入了then说明处理完了一个请求，只要还有处理没请求完，就还会继续处理请求
              this.count--;
              this.request();
            });
        }
      }
      const scheduler = new Scheduler(2);
      const addTask = (time, order) => {
        scheduler.add(time, order);
      };
      addTask(1000, "1");
      addTask(500, "2");
      addTask(300, "3");
      addTask(400, "4");
      //3 2 4 1
      scheduler.taskStart();
    </script>
  </body>
</html>
